974b78e2fa2270ed140eec3977d863ae2ea35464,graylog2-radio/src/main/java/org/graylog2/radio/cluster/InputService.java,InputService,unregisterInCluster,#MessageInput#,126
Before Change
}
public void unregisterInCluster(MessageInput input) throws ExecutionException, InterruptedException, IOException {
final UriBuilder uriBuilder = UriBuilder.fromUri(serverUrl);
uriBuilder.path("/system/radios/" + serverStatus.getNodeId().toString() + "/inputs/" + input.getPersistId());
Future<Response> f = httpclient.prepareDelete(uriBuilder.build().toString())
.setHeader("Content-Type", "application/json")
.execute();
Response r = f.get();
if (r.getStatusCode() != 204) {
throw new RuntimeException("Expected HTTP response [204] for input unregistration but got [" + r.getStatusCode() + "].");
}
}
After Change
}
public void unregisterInCluster(MessageInput input) throws ExecutionException, InterruptedException, IOException {
final URI uri = UriBuilder.fromUri(serverUrl)
.path("/system/radios/{radioId}/inputs/{inputId}")
.build(nodeId.toString(), input.getPersistId());
final Request request = new Request.Builder()
.header(HttpHeaders.CONTENT_TYPE, APPLICATION_JSON)
.delete()
.url(uri.toString())
.build();
final Response r = httpclient.newCall(request).execute();
if (!r.isSuccessful()) {
throw new RuntimeException("Expected HTTP response [2xx] for input unregistration but got [" + r.code() + "].");
}
}